package com.gitee.ykr.lightweight.rpc.protocol.client;

import com.gitee.ykr.lightweight.rpc.common.entity.NettyRpcRequest;
import io.netty.channel.ChannelFuture;

/**
 * @author YKR
 * @Describe
 * @date 2021/8/24
 */
public interface IRequsetInterceptor {

    // 异步调用
    void invokeAsync(ChannelFuture channelFuture, NettyRpcRequest request) throws Exception;

    // 同步调用
    Object invokeSync(ChannelFuture channelFuture, NettyRpcRequest request) throws Exception;
}
